package org.example;

import org.example.MqttDemo.MqttAsync;
import org.example.MqttDemo.MqttConnect;
import org.example.obj.MqttConfiguration;

//TIP To <b>Run</b> code, press <shortcut actionId="Run"/> or
// click the <icon src="AllIcons.Actions.Execute"/> icon in the gutter.
public class Main {
    public static void main(String[] args) {
////        创建配置类
        MqttConfiguration configuration = new MqttConfiguration();
////        连接到broker
//            MqttConnect connect = new MqttConnect(configuration);
//            connect.status();
//             System.out.println(connect.sendMessage("a",false));

        MqttAsync async = new MqttAsync(configuration);
        async.status();
        async.sendMessage("冷冷冷冷冷",false);
    }
}